Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-12667

Incorrect error log on StateDirectory close

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 2.7.0, 2.6.1, 2.8.0
    • 2.6.3, 2.7.2, 2.8.1, 3.0.0
    • streams
    • None

    Description

      In StateDirectory.close() an error is logged about unclean shutdown if all locks are in fact released, and nothing is logged in case of an unclean shutdown.

       

      // all threads should be stopped and cleaned up by now, so none should remain holding a lock
if (locks.isEmpty()) {
 log.error("Some task directories still locked while closing state, this indicates unclean shutdown: {}", locks);
}

       

      Attachments

        Issue Links

          links to

          Web Link GitHub Pull Request #10536

          Activity

            People

              ableegoldman A. Sophie Blee-Goldman
              antrenta Jan Justesen
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: